package drds.binlog.instance.manager;

import drds.binlog.instance.manager.model.BinlogTaskInfo;

/**
 * 对应canal的配置
 */
public class ConfigClient
{

    /**
     * 根据对应的destinantion查询Canal信息
     */
    public BinlogTaskInfo findCanal(String destination)
    {
        // TODO 根据自己的业务实现
        throw new UnsupportedOperationException();
    }

    /**
     * 根据对应的destinantion查询filter信息
     */
    public String findFilter(String destination)
    {
        // TODO 根据自己的业务实现
        throw new UnsupportedOperationException();
    }

}
